package cn.com.zzz.dao;

import java.util.List;

import cn.bbs.ba.base.BADomain;
import cn.bbs.ba.dao.BAADaoOperate;
import cn.bbs.ba.db.Fetcher;
import cn.bbs.ba.util.CommonUntil;
import cn.com.zzz.pk.dto.PkJFFlow;
import cn.com.zzz.util.Constant;

public class PkJFFlowDao extends BADomain {

	/**
	 * 查询用户积分流水
	 * @param pjfdto PkJFFlow
	 * @return 得到的用户
	 */
	public List<PkJFFlow> getJF(PkJFFlow pjfdto, String pageNum) {
	
		pjfdto.setSQLID("searchJFFlowByUserNo");
		// 第几页了，从0开始 0未第一页
		pjfdto.setValue("STARTROWS", CommonUntil.subtract(pageNum, "1"));
		// 每页显示条数
		pjfdto.setValue("ROWS", Constant.ONE_SHOW_NUM);
		
		Fetcher<PkJFFlow> retFetch = BAADaoOperate.search(pjfdto, PkJFFlow.class);
		
		return retFetch.fetchAll();
	}
	
	/**
	 * 插入积分流水表
	 * @param pjfdto PkJFFlow
	 * @return 得到的用户
	 */
	public int insertJF(PkJFFlow pjfdto) {
		
		pjfdto.setSQLID("insertPKJFFlow");
		
		int iCount = BAADaoOperate.update(pjfdto);
		
		return iCount;
	}
	
	/**
	 * 根据用户ID更新积分表
	 * @param pjfdto PkJFFlow
	 * @return 更新条数
	 */
	public int updateJF(PkJFFlow pjfdto) {
		
		pjfdto.setSQLID("updateJFFlow");
		
		int iCount = BAADaoOperate.update(pjfdto);
		
		return iCount;
	}
	
}
